package com.ygctpap.test;

import com.ygctpap.until.RabbitmqProduUntil;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class mqp1 {

    public static void main(String[] args) throws IOException, TimeoutException {
        RabbitmqProduUntil.productMsg("tr","us","tr1","asdfg1");

//        RabbitmqProduUntil.productMsg("tr","us","md","asdf");
//
//        RabbitmqProduUntil.productMsg("tr","us1","md","asdf");
//
//        RabbitmqProduUntil.productMsg("tr","us","md","asdf");

        RabbitmqProduUntil.m_map_exchange_channel.clear();
        RabbitmqProduUntil.m_map_exchange_queue.clear();


        System.out.println("asda");

    }

}
